package com.mojo.concurrent.container;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * 阻塞队列
 * <p>
 * 阻塞队列（Blocking queue）是一个支持两个附加操作的队列，支持阻塞的插入和移除
 * 阻塞插入：当队列满时，队列会阻塞插入元素的线程，直到队列不满
 * 阻塞移除：当队列为空时，获取元素的线程会等待队列不为空
 *
 * @author <a href="mailto:sjj@jianzhimao.com">mojo</a>
 * copyright (C), 2013-2023, 广州九尾信息科技有限公司
 * @date 2023/2/16 14:16
 */
public class BlockingQueue01 {
    public static void main(String[] args) {
        ArrayBlockingQueue<Object> queue = new ArrayBlockingQueue<>(10);
        for (; ; ) {
            queue.add("1");
            break;
        }
        Object remove = queue.remove();
        Object peek = queue.peek();
    }
}
